import psycopg2

# mit Datenbank ber Host-IP, Datenbankname und User verbinden
con = psycopg2.connect ("host=localhost dbname=PrecipitationSahel user=postgres")

# datei bekommt open Befehl mit read Mglichkeit.
datei = open('/Users/Lucia/Desktop/LEder_0800_precip.csv', "r")

# Klasse Cursor ist immer dann erforderlich, wenn Interaktion mit Datanbank stattfinden soll
cur = con.cursor()

# erstellt Tabelle in Datenbank und setzt Spalte 1 auf Primary Key
cur.execute("CREATE TABLE precipitation (ID serial PRIMARY KEY, year integer, precip real);")

# Einlesen der Datei in Postgres Syntax.
# 2.Argument(datei) bezieht sich auf varible mit open-Bezug.
cur.copy_expert("COPY precipitation FROM STDIN Delimiter ','",datei)

# commit Befehl macht Vernderungen sichtbar/dauerhaft
con.commit()

# Kommunikation mit gewhlter Tabelle beenden.
cur.close()

# Kommunikation mit Datenbank beenden.
con.close()
            
